d58701195805ce319002e4f6b9a47d289999a959,products/stratos/modules/integration/test-common/src/main/java/org/apache/stratos/integration/common/TopologyHandler.java,TopologyHandler,assertTopologyInitialized,#,163

Before Change


    private void assertTopologyInitialized() {
        log.info(String.format("Asserting topology initialization within %d ms", TOPOLOGY_INIT_TIMEOUT));
        long startTime = System.currentTimeMillis();
        boolean topologyInitialized = TopologyManager.getTopology().isInitialized();
        while (!topologyInitialized) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException ignore) {
            }
            topologyInitialized = TopologyManager.getTopology().isInitialized();
            if ((System.currentTimeMillis() - startTime) > TOPOLOGY_INIT_TIMEOUT) {
                break;
            }

After Change


    private void assertTopologyInitialized() {
        log.info(String.format("Asserting topology initialization within %d ms", TOPOLOGY_INIT_TIMEOUT));
        long startTime = System.currentTimeMillis();
        while (!TopologyManager.getTopology().isInitialized()) {
            log.info("Waiting for topology to be initialized...");
            sleep(1000);
            if ((System.currentTimeMillis() - startTime) > TOPOLOGY_INIT_TIMEOUT) {
                break;
            }
        }
        if (TopologyManager.getTopology().isInitialized()) {
            log.info(String.format("Topology initialized under %d ms", (System.currentTimeMillis() - startTime)));
        }
        assertTrue(String.format("Topology didn't get initialized within %d ms", TOPOLOGY_INIT_TIMEOUT),